package org.ws.task.item;

import org.ws.task.model.protocol.PullItemRequest;
import org.ws.task.model.TaskItem;

import java.util.Collection;

/**
 * 任务提供者
 */
public interface ItemLeaderProvider<T> {

    /**
     * 获取新的任务项加入到待处理队列
     * 只在Leader端运行
     * @param request
     * @return
     */
    Collection<TaskItem<T>> getItems(PullItemRequest request);

}
